package com.wsjj.yjh.mapper;

import com.wsjj.yjh.bean.FlumeDataxMaxwellSqoopFlinkCDCTable;

import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;

public interface FlumeDataxMaxwellSqoopFlinkCDCTableMapper {
    @Select("select count(*) as flume_datax_maxwell_sqoop_flinkCDC_table from hadoop_table")
    Integer selectCoumt();

    @Select("select * from flume_datax_maxwell_sqoop_flinkCDC_table where id=#{id}")
    FlumeDataxMaxwellSqoopFlinkCDCTable selectById(@Param("id") Integer id);
}
